import mysql from 'mysql2';

const db_config = {
  host: 'localhost',
  user: 'root',
  password: 'root',
  port: 3306,
  database: 'user',
  charset: 'utf8mb4'
};
// 创建数据库连接池
const pool = mysql.createPool(db_config);

/**
 * useMysql 方法
 * @param {string} sql - SQL 查询语句
 * @param {Array} params - 查询参数（可选）
 * @returns {Promise<any>} 查询结果
 */
export async function useMysql(sql, params = []) {
  return new Promise((resolve, reject) => {
    // 检查是否传入参数
    if (params && params.length > 0) {
      // 如果有参数，执行参数化查询
      pool.query(sql, params, (err, result) => {
        if (err) {
          console.error(`查询失败: ${err}`);
          reject(err);
          return;
        }
        resolve(result);
      });
    } else {
      // 如果没有参数，直接执行 SQL 语句
      pool.query(sql, (err, result) => {
        if (err) {
          console.error(`查询失败: ${err}`);
          reject(err);
          return;
        }
        resolve(result);
      });
    }
  });
}